package chapter5.eg3;

import java.util.concurrent.CountDownLatch;

public class ConsumerMain {

  public static void main(String[] args) throws InterruptedException {
    String groupId = "testGroup1";
    String topic = "test-topic";
    int consumerNum = 3;
    ConsumerGroup group = new ConsumerGroup(consumerNum, groupId, topic);
    group.execute();
    new CountDownLatch(1).await();
  }

}
